package day_14.homework;

import java.util.concurrent.ArrayBlockingQueue;

/**
 * @author ck
 * @date2021/8/22 22:41
 */
@SuppressWarnings("all")
public class Cooker_1 extends Thread {
    //创建阻塞队列，要定义一个泛型
    private ArrayBlockingQueue<String> bq;
    //定义一个标记
    private int a = 0;
    //含参数构造方法
    public Cooker_1(ArrayBlockingQueue<String> bq) {
        this.bq = bq;
    }
    //重写run方法
    @Override
    public void run() {
        //死循环
        while (true){
            //try-catch
            try {
                //put方法将你要添加的东西添加进队列中 先进先出
                bq.put("汉堡包");
                System.out.println("厨师放入一个汉堡包");
                a++;
                if (a==10){
                    break;
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
